package org.atguigu.gmall.realtime.join;

import org.apache.flink.streaming.api.datastream.DataStreamSource;
import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;
import org.apache.flink.table.api.bridge.java.StreamTableEnvironment;
import org.atguigu.gmall.realtime.app.BaseApp;
import org.atguigu.gmall.realtime.app.BaseSQLApp;
import org.atguigu.gmall.realtime.util.SQLUtil;

/**
 * @Author zenghaifeng
 * @Date 2023/4/24 23:57
 * @Package: org.atguigu.gmall.realtime.join
 * @Class: ComsumeLeftJoinWithSQLKafka
 * @Description: TODO
 * @Version 1.0
 */
public class ConsumeLeftJoinWithStream extends BaseApp {

    public static void main(String[] args) {
        new ConsumeLeftJoinWithStream().init(50001,2,"ab_left","ConsumeLeftJoinWithStream");
    }
    @Override
    public void handle(StreamExecutionEnvironment env, DataStreamSource<String> ds) {
        ds.print();
    }
}
